package demo.springboot;

import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Service;

@Service
//@RocketMQMessageListener(topic = "TopicTest1", consumerGroup = "Con_Group_One4")
public class ConsumerSend2 implements RocketMQListener<String> {

    @Override
    public void onMessage(String str) {
        System.out.println("ConsumerSend2监听到消息：str="+str);
        throw new RuntimeException("ConsumerSend2模拟消费失败");
    }
    
}
